package cn.itsource._01simple;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * 作者： CTL
 * 描述： 生产者,一对一
 * 创建时间： 2023-06-13 14:06
 */

public class ProducerTest {
    /**
     * @Description 消费队列名
     */
    public static final String AIMPLE_QUEUE_NAME = "helloworld";

    public static void main(String[] args) throws Exception {
        // 1.创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 2.设置连接地址
        factory.setHost("127.0.0.1");
        // 3.创建一个连接对象
        Connection connection = factory.newConnection();
        // 4.从连接对象中创建一个通道
        Channel channel = connection.createChannel();
        // 5.准备一个需要投递的消息
        String msg="hello world RabbitMQ!!!";
        // 6.创建一个队列
        channel.queueDeclare(AIMPLE_QUEUE_NAME,true,false,false,null);
        // 7.发送消息
        channel.basicPublish("",AIMPLE_QUEUE_NAME,null,msg.getBytes());
        // 8.关闭资源
        channel.close();
        connection.close();
        System.out.println("消息投递成功!!!");
        t(3,5);
    }


    public static void t(int a,int b){
        System.out.println(a+b);
    }
}
